import {
	getToken
} from './auth'
import operate from "./operate";

export default class websocketUtil {
	constructor(url, heardTime, vuestore) {
		this.is_open_socket = false //避免重复连接
		this.url = url //地址
		//心跳检测
		this.timeout = heardTime //多少秒执行检测
		this.heartbeatInterval = null //检测服务器端是否还活着
		this.reconnectTimeOut = null //重连之后多久再次重连
		this.store = vuestore
	}

	// 进入这个页面的时候创建websocket连接【整个页面随时使用】
	connectSocketInit() {
		let token = encodeURIComponent(getToken())
		this.socketTask = uni.connectSocket({
			url: this.url,
			protocols: [token], // 真机token传递方式
			complete: (res) => {
				console.log("正准备建立websocket中...");
				console.log(res)
			},
		});
		this.socketTask.onOpen((res) => {
			console.log("WebSocket连接正常！");
			clearTimeout(this.reconnectTimeOut)
			this.is_open_socket = true;
			this.start();
			// 注：只有连接正常打开中 ，才能正常收到消息
			this.socketTask.onMessage((res) => {
				console.log(res.data)
			});
		})
		// 监听连接失败，这里代码我注释掉的原因是因为如果服务器关闭后，和下面的onclose方法一起发起重连操作，这样会导致重复连接
		// uni.onSocketError((res) => {
		// 	console.log('WebSocket连接打开失败，请检查！');
		// 	this.is_open_socket = false;
		// 	this.reconnect();
		// });
		// 这里仅是事件监听【如果socket关闭了会执行】
		this.socketTask.onClose(() => {
			console.log("已经被关闭了")
			this.is_open_socket = false;
			if (getToken()) {
				this.reconnect();
			}
		})
		// 收到消息处理
		this.socketTask.onMessage(result => {
			console.log('收到信息：' + result.data)
			if (getToken()) {
				this.store.dispatch("receiveMsg", result.data)
			}
		})
		this.socketTask.onError(res => {
			console.log('错误信息')
			console.log(res)
		})
		console.log("AABBCC！");
		console.log(this.socketTask);
	}

	//发送消息
	send(value) {
		// 注：只有连接正常打开中 ，才能正常成功发送消息
		this.socketTask.send({
			data: value,
			async success() {
				console.log("消息发送成功");
			},
		});
	}

	//开启心跳检测
	start() {
		this.heartbeatInterval = setInterval(() => {
			let heardData = JSON.stringify({
				value: "ping",
				event: "heartCheck"
			})
			this.send(heardData);
		}, this.timeout)
	}
	//关闭连接
	closeConnect() {
		if (this.socketTask) {
			this.socketTask.close({})
		}
	}

	//重新连接
	reconnect() {
		//停止发送心跳
		clearInterval(this.heartbeatInterval)
		//如果不是人为关闭的话，进行重连
		if (!this.is_open_socket) {
			this.reconnectTimeOut = setTimeout(() => {
				this.connectSocketInit();
			}, 3000)
		}
	}
}
